sqlx4k-mysql/io.github.smyrgeorge.sqlx4k.mysql/[native]MySQL/SqlxConnection

SqlxConnection

class SqlxConnection(rt: CPointer<out CPointed>, cn: CPointer<out CPointed>, val encoders: ValueEncoderRegistry) : Connection(source)

Constructors

SqlxConnection

constructor(rt: CPointer<out CPointed>, cn: CPointer<out CPointed>, encoders: ValueEncoderRegistry)

Properties

encoders

open override val encoders: ValueEncoderRegistry

status

open override val status: Connection.Status

transactionIsolationLevel

open override val transactionIsolationLevel: Transaction.IsolationLevel?

Functions

assertIsOpen

open fun assertIsOpen()

begin

open suspend override fun begin(): Result<Transaction>

open suspend override fun close(): Result<Unit>

execute

open suspend override fun execute(statement: Statement): Result<Long>

open suspend override fun execute(sql: String): Result<Long>

executeWithResult

open suspend override fun executeWithResult(statement: Statement): Result<ExecuteResult>

open suspend override fun executeWithResult(sql: String): Result<ExecuteResult>

fetch

open fun <T> fetch(statement: Statement, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>

open fun <T> fetch(@Language(value = "SQL") sql: String, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>

open override fun fetch(statement: Statement, fetchSize: Int): Flow<ResultSet.Row>

open override fun fetch(sql: String, fetchSize: Int): Flow<ResultSet.Row>

fetchAll

open suspend fun <T> fetchAll(statement: Statement, rowMapper: RowMapper<T>): Result<List<T>>

open suspend fun <T> fetchAll(@Language(value = "SQL") sql: String, rowMapper: RowMapper<T>): Result<List<T>>

open suspend override fun fetchAll(statement: Statement): Result<ResultSet>

open suspend override fun fetchAll(sql: String): Result<ResultSet>

setTransactionIsolationLevel

open suspend override fun setTransactionIsolationLevel(level: Transaction.IsolationLevel): Result<Unit>

transaction

open suspend fun <T> transaction(f: suspend Transaction.() -> T): T

transactionCatching

open suspend fun <T> transactionCatching(f: suspend Transaction.() -> T): Result<T>

withSingleConnection

suspend fun <T> QueryExecutor.withSingleConnection(block: suspend (QueryExecutor) -> Result<T>): Result<T>

Runs block on a single database connection: this executor itself when it already is one (a connection or a transaction), or a connection borrowed from it for the duration of block when it is a pool.